for (AssertionRule rule : assertionRules) {
-    if (rule.shouldRun(outputHapiMessage)) {
-        rule.runRule(outputHapiMessage, inputHapiMessage);
-        runRules.add(rule);
+    try {
+        if (rule.shouldRun(outputHapiMessage)) {
+            rule.runRule(outputHapiMessage, inputHapiMessage);
+            runRules.add(rule);
+        }
+    } catch (Exception e) {
+        logger.logError("Error running rule: " + rule, e);
     }
 }

 public Set<AssertionRule> runRules(Message outputMessage, Message inputMessage) {
     ...
     return runRules;
 }
 
+public boolean allRulesRunSuccessfully() {
+    return assertionRules.equals(runRules);
+}
+

-toRunRules.collect { it.name }.isEmpty()
+assert toRunRules.isEmpty() : "There are still rules that haven't been run: " + toRunRules.collect { it.name }

-def runRules = engine.runRules(outputMessage, inputMessage)
+def runRules = []
+try {
+    runRules = engine.runRules(outputMessage, inputMessage)
+} catch (Exception e) {
+    fail("Failed to run rules due to an exception: " + e.message)
+}
 toRunRules.removeAll(runRules)